package com.cx.thread.message;

/**
 * @author zhangshuai
 * @version V1.0
 * @Project Java2_26
 * @Package com.cx.thread.message
 * @Description:
 * @Date 2025/5/26 16:25
 */

public class Demo1 {
    //1.多个发布者发送消息  存入队列  10  超过10，wait等待阻塞，否则 添加消息，发布消息，并且唤醒所有线程，发布消息
    //2.多个消费者去消费消息  队列种删除，<=0 wait等待阻塞，否则消费消息，删除当前消息，唤醒线程去消费消息
    //发布者，发布消息  发布者线程（执行任务）
    //消费者，消费消息， 消费者线程（消费任务）
}